package com.atguigu.sellcourse.controll

import com.atguigu.sellcourse.service.DwdSellCourseService
import com.atguigu.util.{BaseControll, HiveUtil}
import org.apache.spark.sql.SparkSession

/**
 * description ：读取售课模块表 etl 并写入 dwd 层
 * author      ：剧情再美终是戏 
 * mail        : 13286520398@163.com
 * date        ：Created in 2020/3/10 14:33
 * modified By ：
 * version:    : 1.0
 */
object DwdSellCourseController extends BaseControll {
  override def initAppName(appName: String) = super.initAppName(this.getClass.getName)

  override def doSmething(spark: SparkSession, dt: String, dn: String) = {
    HiveUtil.openDynamicPartition(spark) //开启动态分区
    HiveUtil.openCompression(spark) //开启压缩
    DwdSellCourseService.importSaleCourseLog(spark, dt, dn) // 售课日志
    DwdSellCourseService.importCoursePay(spark, dt, dn) // 支付信息
    DwdSellCourseService.importCourseShoppingCart(spark, dt, dn) // 购物车信息

    DwdSellCourseService.importCoursePayBuket(spark, dt, dn) // 支付信息插入 buket(分桶表)
    DwdSellCourseService.importCourseShoppingCartBuket(spark, dt, dn) // 购物车信息 buket(分桶表)
  }
}
